/**
 * 
 */
package com.servicecloud.provider.service;

import java.util.Map;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

import com.servicecloud.channel.DefaultChannelProcess;

/**
 * @Description 消费者监听rabbitmq，进行消息的消费
 * @author Gavin<br>
 *         2019年8月21日
 */
@Component
//@EnableBinding(Sink.class)//Sink是系统自带的默认的channel通道信息
@EnableBinding(DefaultChannelProcess.class) // 这儿使用自定义的通道
public class MessageListener {
	// @StreamListener(Sink.INPUT)//监听消息队列，默认用系统自定的Sink通道信息
	@StreamListener(DefaultChannelProcess.INPUT) // 使用自定义的消息通道信息
	public void input(Message<Map<String, Object>> message) {
		System.err.println("【**消息接受**】" + message.getPayload());
	}
}
